package org.my.tcp;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

/**
 * 心跳处理
 */
public class HeartBeatServerHandler extends SimpleChannelInboundHandler<String> {
    int readIdleTimes=0;

    /**
     * Channel 收到消息后触发
     * 	*
     * 	* 注：心跳包说白了就是一个某些地方特殊的数据包
     * 	* 	  所以这里我们规定，如果消息内容是 "Heartbeat Packet"，那么它就是一个心跳包
     * @param channelHandlerContext
     * @param s
     * @throws Exception
     */
    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, String s) throws Exception {
        System.out.println("====>[server]message received:"+s);

    }
}
